const db = require('../db/index')

// 上传视频的处理函数
exports.uploadVideo = (req, res) => {
    // 拼接视频url
    const videoUrl = `http://localhost:${process.env.PORT || 8080}/uploads/${req.files.video[0].filename}`

    const sql = `select * from av_video where id = ?`
    db.query(sql, req.body.id, (err, results) => {
        if (err) res.cc(err)
        if (results.length > 0) {
            // 如果存在记录，执行更新操作
            const sqlUpdate = 'update av_video set videoUrl = ? where id = ?'
            db.query(sqlUpdate, [videoUrl, req.body.id], (err, updateResult) => {
                if (err) {
                    return res.cc(err)
                }
                res.cc('更新视频成功!', 0, 20000)
            })
        }
        else {
            // 如果不存在记录，执行插入操作
            const sqlInsert = 'insert into av_video (id,videoUrl) values (?, ?)'
            db.query(sqlInsert, [req.body.id, videoUrl], (err, insertResult) => {
                if (err) {
                    return res.cc(err)
                }
                res.cc('新增视频成功!', 0, 20000)
            })
        }
    })
}

// 上传封面的处理函数
exports.uploadCover = (req, res) => {
    // 拼接封面url
    const coverUrl = `http://localhost:${process.env.PORT || 8080}/uploads/${req.files.cover[0].filename}`

    const sql = `select * from av_video where id = ?`
    db.query(sql, req.body.id, (err, results) => {
        if (err) res.cc(err)
        if (results.length > 0) {
            // 如果存在记录，执行更新操作
            const sqlUpdate = 'update av_video set coverUrl = ? where id = ?'
            db.query(sqlUpdate, [coverUrl, req.body.id], (err, updateResult) => {
                if (err) {
                    return res.cc(err)
                }
                res.cc('更新封面成功!', 0, 20000)
            })
        }
        else {
            // 如果不存在记录，执行插入操作
            const sqlInsert = 'insert into av_video (id,coverUrl) values (?, ?)'
            db.query(sqlInsert, [req.body.id, coverUrl], (err, insertResult) => {
                if (err) {
                    return res.cc(err)
                }
                res.cc('新增封面成功!', 0, 20000)
            })
        }
    })
}

// 上传视频信息的处理函数
exports.uploadInfo = (req, res) => {
    const sql = `select * from av_video where id = ?`

    const updateData = {
        title: req.body.title,
        desc: req.body.desc
    }

    db.query(sql, req.body.id, (err, results) => {
        if (err) res.cc(err)
        if (results.length > 0) {
            // 如果存在记录，执行更新操作
            const sqlUpdate = 'update av_video set ? where id = ?'
            db.query(sqlUpdate, [updateData, req.body.id], (err, updateResult) => {
                if (err) {
                    return res.cc(err)
                }
                res.cc('更新视频信息成功!', 0, 20000)
            })
        }
        else {
            // 如果不存在记录，执行插入操作
            const sqlInsert = 'insert into av_video set ?'
            db.query(sqlInsert, req.body, (err, insertResult) => {
                if (err) {
                    return res.cc(err)
                }
                res.cc('新增视频信息成功!', 0, 20000)
            })
        }
    })
} 